package com.timebank.websocket.mapper;

import com.timebank.websocket.pojo.vo.SendMsgVO;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;

import java.util.List;

/**
 * websocket 消息
 * @author shiliuyinzhen
 */

@Mapper
public interface WSMessageMapper {

    /**
     * 批量新增消息
     * @param getterIds
     * @param sendMsgVO
     * @return
     */
    int batchAddMessage(@Param("getterIds") Long[] getterIds, @Param("msg") SendMsgVO sendMsgVO);

    /**
     * 查询所有消息
     *
     * @param userId
     * @param sendMsgVO
     * @return
     */
    List<SendMsgVO> getWSMessageList(@Param("userId")Long userId, @Param("msg") SendMsgVO sendMsgVO);

    /**
     * 批量确认消息
     *
     * @param userId
     * @param messageIds
     * @return
     */
    int batchConfirmWSMessage(@Param("userId")Long userId, @Param("msgIds") String[] messageIds);
}
